# -*- coding: utf-8 -*-
from datetime import timedelta
from airflow.providers.apache.hdfs.sensors.web_hdfs import WebHdfsSensor
from jms.time_sensor import time_after_01_30

jms_aigroup__yl_cn_lmdm_sys_network = WebHdfsSensor(
    pool='unlimited_pool',
    task_id="jms_aigroup__yl_cn_lmdm_sys_network",
    filepath='/AIGroup/ThreeSegCode/online_address_store/yl_cn_lmdm_sys_network/dt={{ execution_date | cst_ds_nodash }}',
    execution_timeout=timedelta(hours=7),
    email=['yushuo@jtexpress.com','yl_bigdata@yl-scm.com'],
    yarn_queue='pyspark',
    retries=2,
)

jms_aigroup__yl_cn_lmdm_sys_network << time_after_01_30